//package com.lgCore.clientCocurrent;
//
///**
// *
// */
//
//import lombok.extern.slf4j.Slf4j;
//
//import java.util.concurrent.Callable;
//import java.util.concurrent.ConcurrentLinkedQueue;
//import java.util.concurrent.ExecutorService;
//import java.util.concurrent.Executors;
//
///**
// * 事件管理，如接受数据后业务异步处理，可不要返回值
// */
//@Slf4j
//public class FutureTaskScheduler extends Thread {
//    private ConcurrentLinkedQueue<Callable> executeTaskQueue =
//            new ConcurrentLinkedQueue<Callable>();// 任务队列
//    //    private long sleepTime = 200;// 线程休眠时间
//    private int N_CPUS = Runtime.getRuntime().availableProcessors();
//    private ExecutorService pool = Executors.newFixedThreadPool(N_CPUS);
//
//    private static FutureTaskScheduler inst = new FutureTaskScheduler();
//
//    private FutureTaskScheduler() {
//        this.start();
//    }
//
//    /**
//     * 添加任务
//     *
//     * @param executeTask
//     */
//
//
//    public static void add(Callable executeTask) {
//        inst.executeTaskQueue.add(executeTask);
//    }
//
//    @Override
//    public void run() {
//        while (true) {
//            handleTask();// 处理任务
////            threadSleep(sleepTime);
//        }
//    }
//
//    private void threadSleep(long time) {
//        try {
//            sleep(time);
//        } catch (InterruptedException e) {
//            log.error("线程等待异常:", e);
//        }
//    }
//
//    /**
//     * 处理任务队列，检查其中是否有任务
//     */
//    private void handleTask() {
//        Callable executeTask;
//        while (executeTaskQueue.peek() != null) {
//            executeTask = executeTaskQueue.poll();
//            handleTask(executeTask);
//        }
//    }
//
//    /**
//     * 执行任务操作
//     *
//     * @param executeTask
//     */
//    private void handleTask(Callable executeTask) {
//        pool.submit(executeTask);
//    }
//
////    class ExecuteRunnable implements Runnable {
////        Runnable executeTask;
////
////        ExecuteRunnable(Runnable executeTask) {
////            this.executeTask = executeTask;
////        }
////
////        public void run() {
////            executeTask.run();
////        }
////    }
//
//
//    /**
//     * 检查其中是否有任务 true还有，false没有
//     */
//    public static boolean isTask() {
//        while (inst.executeTaskQueue.peek() != null) {
//           return true;
//        }
//        return false;
//    }
//}
